package org.locomotive.station.standard.client;

import java.net.SocketAddress;

import org.locomotive.station.Consumer;
import org.locomotive.station.MessageFilter;
import org.locomotive.station.client.Connector;
import org.locomotive.station.client.Session;
import org.locomotive.station.client.Terminal;

public class StandardConnector implements Connector {
	@Override
	public Terminal connect(SocketAddress serverAddress) {
		return new Terminal() {
			@Override
			public Session session() {
				return null;
			}
			
			@Override
			public void add(Consumer consumer) {
				consumer.consume("Hello clients");
			}
			
			@Override
			public void add(MessageFilter messageFilter) {
			}
			
			@Override
			public void send(Object message) {
			}
		};
	}
}
